package com.test.cyclicBarrierTest;

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

/**
 * @author:wesley
 */
public class CyclicBarrierRunServiceThread extends Thread{


    private CyclicBarrierRunService service;

    public CyclicBarrierRunServiceThread(CyclicBarrierRunService service) {
        this.service = service;
    }

    @Override
    public void run() {
        service.doRun();
    }
}
